package com.muki.wareHouse;

/**
 * 数据仓库
 * @author ljh_2017
 *
 */
public abstract class WareHouse {

	public static WareHouse createWareHouse(Class<?> cls) {
		WareHouse dwh = null;
		try {
			dwh = (WareHouse) cls.newInstance();
		} catch (Exception e) {
			e.printStackTrace();
		}
		return dwh;
	}
	
	abstract public void receive(CorpusParser parser,ListCorpus list);
	
	abstract public CorpusHouse createRemoteCorpusHouse(String ip,int port,String bath_path,String topic);
	
	abstract public CorpusHouse createCorpusHouse(String topic);
}
